package com.tengju.bff.interfaces.covercharge.config;

import org.springframework.context.annotation.Configuration;


/**
 *@author liang_shi
 *@date 2020/11/12 18:10
 *@description 延迟队列消费配置
 */
@Configuration
public class DelayAmqpConfig {


//    @Bean
//    public Queue immediateQueue() {
//        return new Queue(MqMessageConstants.SERVICE_CERT_APPLY_NOTIFY);
//    }
//
//    @Bean
//    public CustomExchange customExchange() {
//        Map<String, Object> args = new HashMap<>();
//        args.put("x-delayed-type", "direct");
//        return new CustomExchange(MqMessageConstants.SERVICE_CERT_APPLY_NOTIFY, "x-delayed-message", true, false, args);
//    }
//
//    @Bean
//    public Binding bindingNotify(@Qualifier("immediateQueue") Queue queue,
//                                 @Qualifier("customExchange") CustomExchange customExchange) {
//        return BindingBuilder.bind(queue).to(customExchange).with(MqMessageConstants.SERVICE_CERT_APPLY_CALLBACK).noargs();
//    }


}
